from uitls import jobRemoteUtil


# 调度器模块 cs 架构： 客户端：构造api request

# callback: 任务回调，执行器执行完任务，回调任务结果
# registry： 执行器注册(调度中心实时感知注册成功的执行器，并发起任务调度
# registryRemove： 执行器注册摘除

class JobAdminBizClient:

    def __init__(self):
        self.addressUrl = None
        self.accessToken = None
        self.timeout = 3

    # 回调： 返回任务执行结果
    def callback(self, handleCallbackParamList):
        return jobRemoteUtil.postBody(self.addressUrl + handleCallbackParamList)

    # 执行器注册
    def registry(self, registryParam):
        return jobRemoteUtil.postBody(self.addressUrl + registryParam)

    # 执行器注册摘除
    def registryRemove(self, registryParam):
        return jobRemoteUtil.postBody(self.addressUrl + registryParam)